package com.settlement.system.service;

import com.settlement.system.model.entity.KafkaSendErrorRecord;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.settlement.system.model.query.KafkaSendErrorRecordQuery;
import com.settlement.system.model.form.KafkaSendErrorRecordForm;
import com.settlement.system.model.vo.KafkaSendErrorRecordImportVo;
import java.util.List;

/**
 * <p>
 * KAFKA发送失败记录表 服务类
 * </p>
 *
 * @author huangrensen
 * @since 2024-09-09
 */
public interface KafkaSendErrorRecordService extends IService<KafkaSendErrorRecord> {

    Page<KafkaSendErrorRecord> getPage(KafkaSendErrorRecordQuery queryParams);

    boolean saveKafkaSendErrorRecord(KafkaSendErrorRecordForm kafkaSendErrorRecordForm);

    KafkaSendErrorRecordForm getKafkaSendErrorRecordFormData(Long id);

    void checkAndSave(KafkaSendErrorRecord kafkaSendErrorRecord);

    boolean deleteKafkaSendErrorRecord(String ids);

    void importData(List<KafkaSendErrorRecordImportVo> importVos);

    List<KafkaSendErrorRecordImportVo> findByIds(String idsStr);

    void reSendAll();
}
